package config;

import cn.demoncat.util.mq.util.MqUtil;
import org.springframework.boot.CommandLineRunner;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;

/**
 * MQ运行管理
 * 
 * @author 延晓磊
 *
 * @since 2017年10月20日
 */
@Component
public class MqRunner implements CommandLineRunner{

	@Resource
	private MqUtil mqUtil;
	
	/**
	 * 项目启动后，开启任务监控MQ延时消息
	 * 
	 * @param args
	 *
	 * @author 延晓磊
	 *
	 * @since 2017年10月20日
	 *
	 */
	@Override
	public void run(String... args) {
		// 监听并补发延时消息
		mqUtil.monitorDelayMessage();
		// 监听并补发延时消息
		mqUtil.monitorDelayMessage("ORDER", 10);
	}

}
